8203d4dbcf8e61a79b72d5e9ac86bda0ff447e77,src/main/java/org/elasticsearch/transport/netty/NettyTransport.java,NettyTransport,disconnectFromNode,#DiscoveryNode#,752
Before Change
@Override
public void disconnectFromNode(DiscoveryNode node) {
synchronized (connectLock(node.id())) {
NodeChannels nodeChannels = connectedNodes.remove(node);
if (nodeChannels != null) {
try {
After Change
public void disconnectFromNode(DiscoveryNode node) {
NodeChannels nodeChannels = connectedNodes.remove(node);
if (nodeChannels != null) {
connectionLock.acquire(node.id());
try {
try {
nodeChannels.close();